//package com.ctl.utils.activemq;
//
//import org.slf4j.Logger;
//import org.slf4j.LoggerFactory;
//
///**
// * <p>Title: Test</p>
// * <p>Description: </p>
// * <p>Copyright: Copyright (c) 2018</p>
// * <p>Company: www.hanshow.com</p>
// *
// * @author guolin
// * @version 1.0
// * @date 2019-03-02 18:40
// */
//public class TestMq {
//    static Logger logger = LoggerFactory.getLogger(TestMq.class);
//
//    public static void main(String[] args){
//        Producter producter = new Producter();
//        producter.init();
//        TestMq testMq = new TestMq();
//        try {
//            Thread.sleep(1000);
//        } catch (InterruptedException e) {
//            e.printStackTrace();
//        }
//        //Thread 1
//        new Thread(testMq.new ProductorMq(producter)).start();
//        //Thread 2
//        new Thread(testMq.new ProductorMq(producter)).start();
//        //Thread 3
//        new Thread(testMq.new ProductorMq(producter)).start();
//        //Thread 4
//        new Thread(testMq.new ProductorMq(producter)).start();
//        //Thread 5
//        new Thread(testMq.new ProductorMq(producter)).start();
//    }
//
//    private class ProductorMq implements Runnable{
//        Producter producter;
//        public ProductorMq(Producter producter){
//            this.producter = producter;
//        }
//
//        @Override
//        public void run() {
//            while(true){
//                try {
//                    producter.sendMessage(ActiveMQConfig.QUEUE_NAME);
//                    Thread.sleep(10000);
//                } catch (InterruptedException e) {
//                    e.printStackTrace();
//                }
//            }
//        }
//    }
//}